let WebSocket = require('ws');

// redis
let redis = require('redis');
// 创建redis客户端 存储的是键值对值是以数组的形式存储的
let client = redis.createClient()
client.on("error", function (error) {
    console.error(error);
});

let wss = new WebSocket.Server({ port: 3000 })

// websoket 连接
wss.on('connection', function (ws) {
    console.log("ws链接成功");
    // 原生的wss就两个常用方法 on('message) 和 send
    ws.send(client.get("key", redis.print))
    // 监听客户端发过来的信息
    ws.on('message', function (data) {
        let arr = []
        arr.push(data)
        client.set('barrages', JSON.stringify(arr), redis.print) // 将弹幕存储到redis里面
        // 然后告诉前端存储成功
        ws.send(data)
    })
})
